package com.atguigu.gmall.realtime.bean;

import lombok.Data;

@Data
public class TableProcess {
    // 动态分流sink常量，改为小写和脚本一致
    public static final String SINK_TYPE_HBASE="hbase";
    public static final String SINK_TYPE_KAFKA="kafka";
    public static final String SINK_TYPE_CK="clickhouse";

    // 来源表
    String sourceTable;
    //操作类型
    String operateType;
    //输出类型
    String sinkType;
    //输出表
    String sinkTable;
    //输出字段
    String sinkColumns;

    //主键字段
    String sinkPk;

    //建表扩展
    String sinkExtend;

}

